#ifndef __MQTT_H
#define __MQTT_H
#include "sys.h"

#define  UPDATA_address        0x08019000 
#define  UPDATA_flagaddress    0x08030000

int do_mqtt_publish(u8 socketnum,int port,int (*getfn)(unsigned char*, int));
int do_mqtt_subscrib(u8 socketnum,char *pTopic,int (*getfn)(unsigned char*, int),int msgid);
char * do_mqtt_subscrib_wait(u8 socketnum,u8 *pMessage,int (*getfn)(unsigned char*, int));
void mqtt_publishMSG(u8 socketnum,char *pTopic,char *pMessage);
#endif
